import redis  # 导入redis包包
import time,threading


# 与本地redis进行链接，地址为：localhost，端口号为6379
r = redis.StrictRedis(host='localhost', port=6379)
r.delete('notrans:')

def notrans():
    #对'notrans:'计数器执行自增操作并打印操作的执行结果
    print(r.incr('notrans:'))
    #等待100毫秒
    time.sleep(.1)
    #对'notrans:'计数器执行自减操作。
    r.incr('notrans:',-1)


if __name__ == '__main__':
    # 启动3个线程来执行没有被事务包裹的自增、休眠和自减操作
    for i in range(3):
        threading.Thread(target=notrans).start()
    # 等待500毫秒，让操作有足够的时间完成
    time.sleep(.5)
